package com.ldy.gkrpc.transport;

import com.ldy.gkrpc.proto.Peer;

import java.io.InputStream;

/**
 * 1.创建连接
 * 2.发送数据，并且等待响应
 * 3.关闭连接
 * @Author songxulin
 * @Date 2020/4/10 19:31
 **/
public interface TransportClient {
    /** 
     *  建立连接 
     * @param  peer 端口信息
     * @return  
     * @Author songxulin
     * @date 2020/4/10 19:35 
    */ 
    void connect(Peer peer);
    /**
     * 写入数据
     * @param data 写入的流信息
     * @return
     * @Author songxulin
     * @date 2020/4/10 19:36
    */
    InputStream write(InputStream data);
    /** 
     *  关闭连接
     * @param  
     * @return  
     * @Author songxulin
     * @date 2020/4/10 19:37 
    */ 
    void close();
}
